package com.msblearn.C_013;

import java.util.Random;
import java.util.concurrent.BlockingDeque;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * 为线程池做准备的;
 * 用链表实现的blockingqueue
 * LinkedBlockingQueue在Queue的基础上还添加了两个方法：put和take。
 * 这两个方法是完全实现了阻塞的。Queue那几个不一定是阻塞的
 * put:往里面添加。当queue满了的时候会阻塞住。
 * take:从queue里面取，当queue为空的时候会阻塞住。
 */
public class T004_BlockingQueue {
    static BlockingQueue<String> strs = new LinkedBlockingQueue<>();
    static Random r = new Random();

    public static void main(String[] args) {
        new Thread(()->{
            for(int i=0;i<100;i++){
                try {
                    strs.put("a"+i);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"T1").start();

        for(int i=0;i<5;i++){
            new Thread(()->{
                for(;;){
                    try {
                        System.out.println(Thread.currentThread().getName()+"take -->"+strs.take());
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            },"C"+i).start();
        }

    }
}
